 
 
 <?php
 
 $base_setting=array('Q_request'=>'flow_request_queue', //等待充值的数据队列
 		'Q_complete'=>'flow_aftercharge_queue', //已经完成充值，等待后续处理的队列
 		'Q_exe'=>'exe_thread_queue', //执行线程队列，已取消
 		'Q_info'=>' thread_info_queue', //线程信息队列，已取消
 		'Q_needcb'=>'need_callback_queue', //等待回调的队列
 			
 		'K_uid'=>'userid', 					    //存储用户ID的key
 		'K_phonenum'=>'phonenum',				//存储手机号码的key
 		'K_package'=>'code',				//存储套餐编码的key
 		'K_operid'=>'operator',				    //存储运营商编号的key
 		'K_state'=>'error_code',				//存储充值状态的key
 		'K_ooid'=>'interface_sn',				//存储运营商侧订单号的key
 		'K_stime'=>'create_time',				//存储开始处理时间的key
 		'K_etime'=>'reply_time',				//存储处理完毕时间的key
 		'K_err_code'=>'oper_code',				//存储运营商错误编码的key
 			
 		'K_sig'=>'user_sig',                     //存储短信签名的key （短信接口需要使用）
 		'K_callback'=>'callback',                //用户回调url（后台使用）
 		'K_pid'=>'parentid',                     //父用户id的key(多层级用户，后台使用)
 		'K_gid'=>'grandid',                      //祖用户id的key(多层级用户，后台使用）
 		'K_uoid'=>'ordersn',                     //用户侧订单号的key(用户查询接口使用)
 		'K_price'=>'price',                      //本请求价格的key(后台使用)
 		'K_time'=>'time',                        //用户发起请求的时间(异常处理使用，当用户请求未发至运营商，可以据此分析)
 		'K_amount'=>'amount',                     //套餐大小的key(短信提示用)
 		'K_csn'=>'sn',                             //流量券的sn
 			
 		'rec_struc'=>'hash'                       //数据结构(hash或set)
 );
 
 
 
 
   
$conf['conf']['foo'] = 'this is foo';
$conf['conf']['bar'] = 'this is bar';

function foobar() {
	global $conf;
	var_dump($conf);
	var_dump($GLOBALS['base_setting']['K_state'] ) ;
	
	
}

foobar();

/*
 result is..

 array
 'conf' =>
 array
 'foo' => string 'this is foo' (length=11)
 'bar' => string 'this is bar' (length=11)

*/
?>
 
 <?php
 
 error_reporting(E_ALL );
 
$result='error';
$channelID=5;
 
//updateCurrentConnStatus($channelID ,$result,"YD01");
 

/*
 * function updateCurrentConnStatus
 * 主要功能： 根据充值返回值更新redis键:channel_x 通道当前连接状态;
 * 输入：  channelID:通道对应的值；result :通道返回值，ok是成功 ；$package_code：YD01
 * 输出： 
 */

 function  updateCurrentConnStatus ($channelID, $result,$package_code )
 {  
 	$redis = new Redis();     //测试添加！！！！！
$redis->connect('127.0.0.1', 6379);  //测试添加！！！！！
 	switch (substr($package_code,0,2)) {
 	
 		case "YD" :
 			$conn_field="cm_conn_status";
 			break;
 		case "LT" :
 			$conn_field="cu_conn_status";
 			break;
 		case "DX" :
 			$conn_field="ct_conn_status";
 			break;
 		default :
 			$conn_field="ct_conn_status";
 	}
  echo "multi_mall_oper_frouter:[".__FILE__."] line:[".__LINE__."]\$conn_field：". $conn_field . "<br/>\r\n";
 	
$conn_status=$redis->hget ("channel_" . $channelID,$conn_field)   ;
var_dump($redis->hget("channel_" . $channelID ,$conn_field));  //结果：bool(false)

if ($result ==='ok')
{
   $conn_status=(($conn_status+0.1)<=1)?($conn_status+0.1):1;
     
} else
  {
     $conn_status=(($conn_status-0.1)>0.3)?($conn_status-0.1):0.4;
  }

$redis->hset ( "channel_" . $channelID,$conn_field, $conn_status );

var_dump($redis->hget("channel_" . $channelID ,$conn_field));  //结果：bool(false)

}



?>